package cn.itcast.streaming.utils;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

/**
 * 文件读写工具类
 *  加载配置文件，加载key对应的value
 */
public class ConfigLoader {

    /**
     * 1.使用classLoader加载对象，然后加载conf.properties
     * 2.使用properties的load方法加载inputStream
     * 3.获取key的value
     * 4.获取int类型key对应的value值
     */

    //todo 1.使用classLoader加载对象，然后加载conf.properties
    private final static InputStream inputStream = ConfigLoader.class.getClassLoader().getResourceAsStream("conf.properties");

    //todo 2.使用properties的load方法加载inputStream
    private final static Properties props = new Properties();

    static {
        try {
            props.load(inputStream);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    //todo 3.获取key的value

    public static final String getProperty(String key){
        return props.getProperty(key);
    }
    //todo 4.获取int类型key对应的value值
    public final static Integer getInteger(String key){
        return Integer.parseInt(props.getProperty(key));
    }

    public static void main(String[] args) {
        System.out.println(getProperty("kafka.topic"));
    }

    public static InputStream getInputStream() {
        return inputStream;
    }
}
